google.golang.org/grpc.addrConnStream.s (field)
14 uses
google.golang.org/grpc (current package)
stream.go#L1251: as.s = s
stream.go#L1273: s *transport.Stream
stream.go#L1295: m, err := as.s.Header()
stream.go#L1303: return as.s.Trailer()
stream.go#L1313: as.t.Write(as.s, nil, nil, &transport.Options{Last: true})
stream.go#L1322: return as.s.Context()
stream.go#L1354: if err := as.t.Write(as.s, hdr, payld, &transport.Options{Last: !as.desc.ClientStreams}); err != nil {
stream.go#L1380: if ct := as.s.RecvCompress(); ct != "" && ct != encoding.Identity {
stream.go#L1394: err = recv(as.p, as.codec, as.s, as.dc, m, *as.callInfo.maxReceiveMessageSize, nil, as.decomp)
stream.go#L1397: if statusErr := as.s.Status().Err(); statusErr != nil {
stream.go#L1415: err = recv(as.p, as.codec, as.s, as.dc, m, *as.callInfo.maxReceiveMessageSize, nil, as.decomp)
stream.go#L1420: return as.s.Status().Err() // non-server streaming Recv returns nil on success
stream.go#L1436: if as.s != nil {
stream.go#L1437: as.t.CloseStream(as.s, err)